package cn.com.wind.bdg.polish.polish.service;

import java.util.List;

public interface KafkaService {
    /**
    *@Description 初始化Kafka生产者及消费者
    *@Param []
    *@Return void
    *@Author wsun.Frank
    *@Date 2020/8/13
    */
    public void init();
    /**
    *@Description 消费kafka消息
    *@Param []
    *@Return void
    *@Author wsun.Frank
    *@Date 2020/8/13
    */

    public List<String> consume();
    /**
    *@Description 生产kafka消息
    *@Param [key, value] 消息的key和value
    *@Return void
    *@Author wsun.Frank
    *@Date 2020/8/13
    */

    public void produce(String key, String value);
    /**
    *@Description 关闭释放资源
    *@Param []
    *@Return void
    *@Author wsun.Frank
    *@Date 2020/8/13
    */
    public void reqClose();

    public void resetOffset();
}
